package cn.doitedu.day05

import cn.doitedu.day01.utils.SparkUtil

/**
 * @Date 22.4.3
 * @Created by HANGGE
 * @Description
 */
object A01_行动算子_collect {
  def main(args: Array[String]): Unit = {
    val sc = SparkUtil.getSc

    val words = sc.textFile("data/a.txt").flatMap(_.split("\\s+"))

     // 将RDD中各个分区的所有数据收集到本地  数组中
    // 数据量 不要很大
    val arr: Array[String] = words.collect()  // 行动算子
    arr.foreach(println)

    // 收集Map   本地集合
    val rdd2 = words.map((_, 1))
    val mp: collection.Map[String, Int] = rdd2.collectAsMap()

  }

}
